package com.originit.product.server.mq;

import lombok.extern.slf4j.Slf4j;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.stereotype.Component;

@Component
@Slf4j
public class MessageReceiver {

    @StreamListener(StreamInterface.KEY)
    public void receive(Object message){
        log.error("接收到消息： {}", message);
    }
}
